package mqtt5;

/**
 * @Title: Mqtt3StartDemo
 * @Package: cn.mis.util.mqtt3
 * @Description:
 * @Author: ChenLi
 * @Date: 2023/2/15 - 15:10
 */

public class Mqtt5StartDemo {
    public static void main(String[] args) {
        /**初始化创建客户端,在合适的时机进行调用，可放到主启动类中进行执行**/
        MQTT5START.run();
        /**开始调用*/
        //获取需要调用的客户端
        Mqtt5Client client = MQTTCLIENTS.CLIENTSMAP.get("clientName");
        //消息发布,默认消息质量为0，属于广播，不一定能够保证目标能够百分百收到。适用于发送不太重要的信息
        client.sendMessege("topic","消息体");

        //若在启动的时候，自身主题不够用，可以直接调用此方法进行增加主题订阅。
        client.subscribe("topic", 2);
    }
}
